package com.zwj.app.api;

import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;

import javax.annotation.Resource;

/**
 * 卡夫卡生产者
 *
 * @author 张文接
 * @version 1.0
 * @createTime 2024/3/25 21:46
 */
@RestController
public class KafkaProducer {
    /**
     * 卡夫卡模板
     */
    @Resource
    private KafkaTemplate<String, Object> kafkaTemplate;

    /**
     * 我的kafka第一个生产者案例
     * @param message 消息
     */
    @GetMapping("/kafka/normal")
    public void sendNormalMessage(@PathVariable("message") String message) {
        kafkaTemplate.send("wxy-topic", message);
    }
}
